package com.yboot.starter.caffeine.core;

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.yboot.starter.api.core.cache.CacheService;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.TimeUnit;

/**
 * 功能描述
 *
 * @author yangcs
 * @date 2025/8/11
 */
@Slf4j
public class LocalCache implements CacheService {
    private Cache<String, Object> localCache = null;

//    @PostConstruct
    public void init() {
        localCache = Caffeine.newBuilder()
                // 初始容量
                .initialCapacity(10)
                // 最大缓存数量
                .maximumSize(50)
                // 缓存过期时间：写入缓存后，经过某个时间缓存失效
                .expireAfterWrite(60, TimeUnit.MINUTES)
                // 缓存失效监听器
                .removalListener((key, value, cause) -> log.info("key:{} value:{} cause:{}", key, value, cause))
                // 开启统计功能 .recordStats()
                .build();
    }

    public void setCache(String key, Object object){
        localCache.put(key,object);
    }

    /***
     * 返回值 如果不存在返回null
     * @param key
     * @param <T>
     * @return
     */
    public <T> T getCache(String key){
        return (T) localCache.getIfPresent(key);
    }

    public void delete(String key){
        localCache.invalidate(key);
    }
}
